import { getToken } from '@/utils/auth';
import { ElNotification } from 'element-plus';
import useNoticeStore from '@/store/modules/notice';
import { parseTime } from '@/utils/ruoyi';
import {contain} from "echarts/types/src/scale/helper";

// 初始化
export const initSSE = (url: any) => {
  if (import.meta.env.VITE_APP_SSE === 'false') {
    return;
  }

  url = url + '?Authorization=Bearer ' + getToken() + '&clientid=' + import.meta.env.VITE_APP_CLIENT_ID;
  const {
    data,
    error
  } = useEventSource(url, [], {
    autoReconnect: {
      retries: 10,
      delay: 3000,
      onFailed() {
        console.log('Failed to connect after 10 retries');
      }
    }
  });

  watch(error, () => {
    console.log('SSE connection error:', error.value);
    error.value = null;
  });

  watch(data, () => {
    if (!data.value) return;
    const res = data.value.split('~');
    let id = '0';
    let time = new Date().toLocaleString();
    if (res.length == 3) {
      id = res[1];
      time = parseTime(res[2]);
    }

    let isType = res[0].includes('type');

    useNoticeStore().addNotice({
      id: id,
      message: res[0],
      // 1是显示未处理数量 2 未读
      type: isType ? 1 : 2,
      read: false,
      time: time
    });

    if (!isType) {
      ElNotification({
        title: '消息',
        message: data.value.split('~')[0],
        type: 'success',
        duration: 3000
      });
    }

    data.value = null;
  });
};
